package com.market.goods.producer;

public interface KafkaClusterProducer {

    void send(String message);

    /**
     * 发送标准消息异步无阻塞
     * @param message
     */
    void sendToKafkaStandardMessageAsync(String topic,String message);


    /**
     * 发送标准消息同步有阻塞
     * @param message
     */
    void sendToKafkaStandardMessageSync(String message);

    void executeInTransaction(String message);

}
